package com.tensai.study.新概念.响应式编程.reactor.flux;

import org.junit.Test;
import reactor.core.publisher.Flux;

/**
 * @author Tensai
 */
public class ReduceTest {
    @Test
    public void test() {
        /* 聚合操作（聚合方式） */
        Flux.just(1, 2, 3).reduce(Integer::sum).subscribe(System.out::println);
        System.out.println("----------------------------------");
        /* 合并聚合操作（合并目标，聚合方式） */
        Flux.just(1, 2, 3).reduceWith(() -> 4, Integer::sum).subscribe(System.out::println);

    }
}
